package com.zh.common.service.impl;

import com.zh.common.service.RabbitMQService;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

/**
 * 发送消息
 */
@Service
public class RabbitMQServiceImpl implements RabbitMQService {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Override
    public void sendMsgToDirect(String ex, String routingKey, String json) {
        // 参数说明，
        // ex:  交换机
        // routingKey： routingKey 路由
        // json:  要发送的数据
        rabbitTemplate.convertAndSend(ex,routingKey,json);
    }

    @Override
    public void sendMsgToTopic(String ex, String routingKey, String json) {
        // 参数说明，
        // ex:  交换机
        // routingKey： routingKey 路由
        // json:  要发送的数据
        rabbitTemplate.convertAndSend(ex,routingKey,json);
    }

    @Override
    public void sendMsgToFanout(String ex, String json) {
        // 参数说明，
        // ex:  交换机
        // routingKey： routingKey 路由
        // json:  要发送的数据
        rabbitTemplate.convertAndSend(ex,null,json);
    }
}
